package com.taobao.txc.rm.mq;

import com.aliyun.openservices.shade.com.alibaba.rocketmq.client.exception.MQClientException;
import com.aliyun.openservices.shade.com.alibaba.rocketmq.client.producer.SendResult;
import com.aliyun.openservices.shade.com.alibaba.rocketmq.common.message.Message;
import com.taobao.txc.resourcemanager.mt.MtBranch;

public abstract interface TxcMQProducer
{
  @MtBranch(name="TxcMetaQProducer.send", commitMethod="commit", rollbackMethod="rollback")
  public abstract SendResult send(String paramString, long paramLong, Message paramMessage)
    throws MQClientException;
  
  public abstract boolean rollback(String paramString1, long paramLong, String paramString2);
  
  public abstract boolean commit(String paramString1, long paramLong, String paramString2);
  
  public abstract void start()
    throws MQClientException;
  
  public abstract void shutdown();
}


/* Location:           C:\Users\ibm\Downloads\txc-yun-sample (1)\txc-yun-sample\lib\txc-client-2.0.72.jar
 * Qualified Name:     com.taobao.txc.rm.mq.TxcMQProducer
 * JD-Core Version:    0.7.0.1
 */